package com.sky.scheduletask;

import com.sky.websocket.WebSocketServer;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;

@Component
@Slf4j
public class WebSocketTask {
    @Autowired
    private WebSocketServer webSocketServer;//注入WebSocketServer与前端建立连接并且进行消息的自动实时推送

//    /**
//     * 定时任务,每5秒执行一次,向所有客户端推送实时消息
//     */
//    @Scheduled(cron = "0/5 * * * * ?")//每5秒执行一次
//    public void sendWebSocketMsg() {
//        log.info("websocket定时任务 开始推送消息");
//        webSocketServer.sendToAllClient("这是来自服务端的实时推送群发信息"
//        + DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(LocalDateTime.now())
//        );//向所有客户端发送消息
//
//    }

    /**
     * 创建一个时间日期格式化器,指定日期格式,去格式化当前时间
     * DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss").format(LocalDateTime.now())
     * @return
     */
}
